﻿using Confluent.Kafka;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace ConsoleAppKafkaTest
{
    class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine($"请输入要启动的模式：[1 生产者] [2 消费者]");
            string inputNumber = Console.ReadLine();
            switch (inputNumber)
            {
                case "1":
                    KafkaProducerDemo.TestProducer();
                    break;
                case "2":
                    KafkaConsumerDemo.TestConsumer();
                    break;
                default:
                    break;
            }
          
        }
    }


}
